package com.xbongbong.schedule.binders;

import com.xbongbong.schedule.constant.ScheduleTaskMqProducerConstant;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;

@Service("scheduleTaskMqProducerBinder")
public interface ScheduleTaskMqProducerBinder {

    @Output(ScheduleTaskMqProducerConstant.SCHEDULE_TASK_OUTPUT)
    MessageChannel scheduleTaskOutput();

    @Output(ScheduleTaskMqProducerConstant.SCHEDULE_TASK_IMMEDIATELY_OUTPUT)
    MessageChannel scheduleTaskImmediatelyOutput();
}
